package com.ionehe.group.common.notify.rocketmq.flags;

import com.ionehe.group.common.notify.message.vendors.KeyFlag;

/**
 * Copyright (c) 2021 ionehe.com
 * Date: 2021/4/21
 * Time: 1:22 下午
 *
 * @author 2021年 <a href="mailto:a@ionehe.com">秀</a>
 * 【rocketmq配置key】
 */
public class RocketKeyFlags {
    public static final KeyFlag FLAG_PRODUCER_GROUP = new KeyFlag("ProducerGroup", true);
    public static final KeyFlag FLAG_SEND_MSG_TIMEOUT = new KeyFlag("SendMsgTimeout", true, Integer.valueOf(3000));
    public static final KeyFlag FLAG_MSG_SIZE = new KeyFlag("MsgSize", true, Integer.valueOf(131072));
    public static final KeyFlag FLAG_CONSUMER_GROUP = new KeyFlag("ConsumerGroup", true);
    public static final KeyFlag FLAG_CONSUMER_MODEL = new KeyFlag("ConsumerModel", true, "CLUSTERING");
    public static final KeyFlag FLAG_INSTANCE_NAME = new KeyFlag("InstanceName", true);
    public static final KeyFlag FLAG_NAMESRVADDR = new KeyFlag("NameServerAddress", true);
    public static final KeyFlag FLAG_CONSUMERTHREADNUMBER = new KeyFlag("ConsumerThreadNumber", false);
}
